package cspro;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.Socket;
/**
 * 客户端
 * 
 * @author: cyj
 * @date: 2017年10月9日 下午1:01:59
 */
public class Client {


	/**
	 * 连接服务器 并返回socket对象
	 * @param ipAdress
	 * @param port
	 * @return
	 * @author: cyj
	 * @date: 2017年10月9日 下午1:02:14
	 */
	public static Socket connect(String ipAdress,int port){
		Socket socket = null;
		try {
			/** 创建Socket*/
			// 创建一个流套接字并将其连接到指定 IP 地址的指定端口号(本处是本机)
			socket =new Socket(ipAdress,port);
			// 60s超时
			socket.setSoTimeout(60000);
		}catch (Exception e) {
			System.out.println("Exception:" + e);
		}
		return socket;
	}	

	
	/**
	 * 获取从服务器读取到的数据
	 * @param socket
	 * @return
	 * @author: cyj
	 * @date: 2017年10月9日 下午1:07:52
	 */
	public static String receiveMsg(Socket socket){
		// 输入读入一字符串
		String result = null;
		try {
			BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			result = bufferedReader.readLine();
			System.out.println("Server say : " + result);
		} catch (IOException e) {
			e.printStackTrace();
		}
		return result;
	}
}

